#include "QueueMananger.h"

#include <QDebug>

QueueMananger* QueueMananger::instance = 0;

QueueMananger* QueueMananger::get()
{
    if ( !instance )
    {
        instance = new QueueMananger();
    }
    return instance;
}

QueueMananger::QueueMananger()
{
}

QueueMananger::~QueueMananger()
{
}

void QueueMananger::pushRequest( QByteArray& message )
{    
    if ( !message.isEmpty() )
    {
        requestQueue.enqueue( message );
    }
}

QByteArray QueueMananger::popRequest()
{
//    qDebug() << "request enqueue: " << requestQueue.size();
    if ( !requestQueue.isEmpty() )
    {
        return requestQueue.dequeue();
    }
    return QByteArray();
}


void QueueMananger::pushResponse( QByteArray& message )
{    
    if ( !message.isEmpty() )
    {
        responseQueue.enqueue( message );
    }
}

QByteArray QueueMananger::popResponse()
{    
//    qDebug() << "response enqueue: " << responseQueue.size();
    if ( !responseQueue.isEmpty() )
    {
        return responseQueue.dequeue();
    }
    return QByteArray();
}
